# 数据库操作：增、删、改、查

import pymysql

# 使用参数名创建连接
conn = pymysql.connect(
    host='192.168.18.76',
    port=3306,
    user='admin',
    passwd='Root123456!',
    db='hrdata',
    charset='utf8'
)
print("数据库连接成功！")
print(conn)
# 1. 连接数据库并且创建一张表
# 创建表
# sql = "create table if not exists xuweijie" \
#       "(id int(10) primary key auto_increment, " \
#       "name varchar(20) not null, text varchar(20) not null)"
# 创建游标
cursor = conn.cursor()

# cursor.execute(sql)
# cursor.execute("show tables")
# print(cursor.fetchall())

# 插入数据
sql = "insert into xuweijie (name, text) value (%s, %s)"
names = ['安欣', '高启强', '李有田', '容嬷嬷', '五阿哥']
texts = [
    '比不上卖鱼的人认了干爹',
    '风浪越大，鱼越贵',
    '杀人犯是高启强啊',
    '看我扎不扎你就完了',
    '紫薇等一下'
]
# 执行插入一条数据语句
# cursor.execute(sql, (names[0], texts[0]))

# 第一种方法：执行插入多条数据的语句
# for (index, name) in enumerate(names):
#     cursor.execute(sql, (name, texts[index]))

# 第二种方法：一次性执行插入一个列表
# list = [('安欣', '比不上卖鱼的人认了干爹1'), ('高启强', '风浪越大，鱼越贵1'),
#         ('李有田', '杀人犯是高启强啊1'), ('容嬷嬷', '看我扎不扎你就完了1'),
#         ('五阿哥', '紫薇等一下1')]
# cursor.executemany(sql, list)

# 提交事务
# conn.commit()

# 修改数据
# update_sql = "update xuweijie set name='李宏伟' where id=14"
# cursor.execute(update_sql)

# 删除某一条记录
# delete_sql = "delete from xuweijie where id=1"
# cursor.execute(delete_sql)
# conn.commit()
# 删除语句是数据库操作中极少执行
# 清空表：删除表中所有数据并且保留表结构，注意：不能撤销还原
clear_table_sql = "truncate table xuweijie"
cursor.execute(clear_table_sql)
conn.commit()

# 提交数据以后查询表
query_sql = "select * from xuweijie"
cursor.execute(query_sql)
print(cursor.fetchall())
conn.close()




